package com.wx;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
 * 点对点
 */
public class QueueProducer {

    public static void main(String[] args) throws JMSException {
        //1.创建连接工厂
        ConnectionFactory connectionFactory=
                new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");
        //2.创建连接
        Connection connection=connectionFactory.createConnection();
        //3.启动连接
        connection.start();
        //4.获取session（会话对象） 参数1：是否启动事务 参数2：消息确认方式
        Session session=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
        //5.创建队列对象
        Queue queue=session.createQueue("test-wx-queue");
        //6.创建消息生产者对象
        MessageProducer producer=session.createProducer(queue);
        //7.创建消息对象
        TextMessage textMessage = session.createTextMessage("欢迎来到米线网");
        //8.发送消息
        producer.send(textMessage);
        //9.关闭资源
        producer.close();
        session.close();
        connection.close();
    }
}
